b155f66e08bb788c54aa16133c18c14c5bf50f14,src/freenet/client/async/SplitFileFetcherSegment.java,SplitFileFetcherSegment,makeBlocks,#PersistentChosenRequest#RequestScheduler#KeysFetchingLocally#SplitFileFetcherSegmentGet#ObjectContainer#ClientContext#,2252
Before Change
if(l < now) continue; // Okay
i.remove();
// Concurrency is fine here, it won't go away before the given time.
setMaxCooldownWakeup(l, ((SplitFileFetcherSegmentSendableRequestItem)block.token).blockNum, maxTries, container, context);
}
return list;
}
After Change
long l = fetching.checkRecentlyFailed(block.key, realTimeFlag);
if(l < now) continue; // Okay
i.remove();
if(maxRetries == -1 || (maxRetries >= RequestScheduler.COOLDOWN_RETRIES)) {
// Concurrency is fine here, it won't go away before the given time.
setMaxCooldownWakeup(l, ((SplitFileFetcherSegmentSendableRequestItem)block.token).blockNum, maxTries, container, context);
} else {
onNonFatalFailure(new FetchException(FetchException.RECENTLY_FAILED), ((SplitFileFetcherSegmentSendableRequestItem)(block.token)).blockNum, container, context);
}
}
return list;